class websocketUtil {
    constructor (url, time) {
        this.is_open_socket = false //避免重复连接
        this.url = url //地址
        this.data = null
        //心跳检测
        this.timeout = time //多少秒执行检测
        this.heartbeatInterval = null //检测服务器端是否还活着
        this.reconnectTimeOut = null //重连之后多久再次重连

        try {
            return this.connectSocketInit()
        } catch (e) {
            console.log('catch');
            this.is_open_socket = false
            this.reconnect();
        }
    }

    // 进入这个页面的时候创建websocket连接【整个页面随时使用】
    connectSocketInit (onMessage) {
        this.socketTask = uni.connectSocket({
            url: this.url,
            success: () => {
                console.log("正准备建立websocket中...");
                // 返回实例
                return this.socketTask
            },
        });
        this.socketTask.onOpen((res) => {
            console.log("WebSocket连接正常！");
            clearTimeout(this.reconnectTimeOut)
            clearTimeout(this.heartbeatInterval)
            this.is_open_socket = true;
            // this.start();
        })
        this.socketTask.onClose((e) => {
            console.log(e)
            console.log("已经被关闭了")
            this.is_open_socket = false;
            this.reconnect();
        })
    }

    //发送消息
    send (value) {
        // 注：只有连接正常打开中 ，才能正常成功发送消息
        this.socketTask.send({
            data: JSON.stringify(value),
            async success () {
            },
        });
    }

    //开启心跳检测
    start () {
        this.heartbeatInterval = setTimeout(() => {
            this.send('心跳');
        }, this.timeout)
    }

    //重新连接
    reconnect () {
        //停止发送心跳
        clearInterval(this.heartbeatInterval)
        //如果不是人为关闭的话，进行重连
        if (!this.is_open_socket) {
            this.reconnectTimeOut = setTimeout(() => {
                this.connectSocketInit();
            }, 3000)
        }
    }
}

export default websocketUtil
